package com.xframe.event.bus.core.msg;

import com.rabbitmq.client.BuiltinExchangeType;
import com.rabbitmq.client.Connection;

public class TopicReceiveMsg extends DirectReceiveMsg {
    public TopicReceiveMsg(Connection msgConn, IMsgProc msgProc, String queueName, String exchange, String routingKeys) {
        super(msgConn, msgProc, queueName, exchange, routingKeys);
    }

    @Override
    protected BuiltinExchangeType getBuiltinExchangeType(){
        return BuiltinExchangeType.TOPIC;
    }


}
